package com.ruoyi.stream.framework.core.workDomain.io.consumeHandlers;

import com.ruoyi.stream.framework.core.workDomain.SingleIOTask;
import com.ruoyi.stream.framework.core.workDomain.io.ConsumeIO;

public class CommonConsume implements ConsumeIO {
    @Override
    public void consume(SingleIOTask task) {
        task.getChannel().writeAndFlush(task.getCache());
    }
}
